package cn.hy.dataSync.config;


public class CoreConstant {
    public static final String FLOW_CONTROL_INTERVAL = "flow_control_interval";

    public static final String CHANNEL_SPEED_RECORD = "channel_speed_record";

    public static final String CHANNEL_CAPACITY = "channel_capacity";

    public static final String EXCHANGER_BUFFER_SIZE = "exchanger_buffer_size";

    public static final String JOB_REPORT_INTERVAL = "job_report_interval";

    public static final String JOB_SLEEP_INTERVAL = "job_sleep_interval";

    public static final String TASK_REPORT_INTERVAL = "task_report_interval";

    public static final String TASK_SLEEP_INTERVAL = "task_sleep_interval";

    public static final String TASK_FAILOVER_MAX_RETRY_TIMES = "task_failover_max_retry_times";

    public static final String TASK_FAILOVER_RETRY_INTERVAL_INMSEC = "task_failover_retry_interval_inmsec";

    public static final String TASK_FAILOVER_MAX_WAIT_INMSEC = "task_failover_max_wait_inmsec";

    public static final String TASK_CORE_TRANSPORT_CHANNEL_CLASS = "core.transport.channel.class";

    public static final String TASK_CORE_TRANSPORT_CHANNEL_DEFAULT =
            "cn.hy.dataSync.transport.channel.memory.MemoryChannel";

    public static final String TASK_CORE_TRANSPORT_RECORD_CLASS = "core.transport.record.class";

    public static final String TASK_CORE_TRANSPORT_RECORD_DEFAULT =
            "cn.hy.dataSync.transport.record.DefaultRecord";

    public static final String TASK_CORE_STATISTICS_COLLECTOR_CLASS = "core.statistics.collector.taskClass";

    public static final String TASK_CORE_STATISTICS_COLLECTOR_DEFAULT =
            "cn.hy.dataSync.statistics.dirty.TaskDirtyCollector";
}
